package com.yang.spark.streaming

import org.apache.spark.SparkConf
import org.apache.spark.streaming.{Seconds, StreamingContext}

/**
  * Created by yang on 2018/7/2. 
  */
object wordcount {

  def main(args: Array[String]): Unit = {
    val conf = new SparkConf().setAppName("asdf")
    val ssc = new StreamingContext(conf,Seconds(10))

  }

}
